package com.qf.listener;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
public class MyStreamListener {
//  从指定级交换机中监听消息
    @StreamListener("buxiangshoushilantanzi")
    public void onMessage(String msg){
        System.out.println("通过listener 收到的消息"+msg);
    }

}
